package com.njmt.cloud.msprovder.controller;

/**
 * @author <a href="mailto:xingxiao@gtmap.cn">xingxiaofeng</a>
 * @version2.1 2022-04-24
 * @description
 */
import com.njmt.cloud.msprovder.KafakaSendService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class KafakaProducerController {

    @Autowired
    private KafakaSendService kafakaSendService;

    @RequestMapping("/send/{msg}")
    public void send(@PathVariable String msg) {
        kafakaSendService.sendMsg(msg);
    }
}
